module teapo.storage.attached.indexedDB {

​

  export class StorageAccess implements attached.StorageAccess {

​

    constructor(private _db: IDBDatabase) {

    }

​

    update(

      byFullPath: PropertiesByFullPath,

      timestamp: number,

      callback: (error: Error) => void): void {

​

      var transaction = this._db.transaction(['files', 'metadata'], 'readwrite');

      transaction.onerror = (errorEvent) => callback(wrapErrorEvent(errorEvent, 'update: transaction'));

      var filesStore = transaction.objectStore('files');

      var outstandingRequests = 1;

​

      function oneError(errorEvent: ErrorEvent, moreDescription) {

        if (!outstandingRequests) return;

​

        outstandingRequests = 0;

        callback(wrapErrorEvent(errorEvent, moreDescription));

      }

​

      function oneCompleted() {

        if (!outstandingRequests) return;

​

        outstandingRequests--;

        callback(null);

      }

​

      for (var fullPath in byFullPath) if (byFullPath.hasOwnProperty(fullPath)) {

​

        var pbag = byFullPath[fullPath];

​

        if (!pbag) {

          var deleteRequest = filesStore['delete'](fullPath);

          outstandingRequests++;

          deleteRequest.onerror = (errorEvent) => oneError(errorEvent, 'update: objectStore(files).delete(' + fullPath+')');

          deleteRequest.onsuccess = (event) => {

            oneCompleted();

          };

        }

        else {

          var getRequest = filesStore.get(fullPath);

          outstandingRequests++;

​

          getRequest.onerror = (errorEvent) => oneError(errorEvent, 'update: objectStore(files).delete(' + fullPath + ')');

          getRequest.onsuccess = (event) => {

​

            var fileData: FileData = getRequest.result || { path: fullPath, properties: {} };

​

            var properties = fileData.properties || (fileData.properties = {});

            for (var p in pbag) if (pbag.hasOwnProperty(p)) {

              var v = pbag[p];

              if (v === null || typeof v === 'undefined')

                delete properties[p];

              else

                properties[p] = v;

            }

​

            var putFile = filesStore.put(fileData);

            getRequest.onerror = (errorEvent) => oneError(errorEvent, 'update: objectStore(files).put(' + fullPath + ')');

            putFile.onsuccess = (event) =>

              this._updateEditedUTC(

                timestamp,

                transaction,

                (errorEvent) => callback(wrapErrorEvent(errorEvent, 'update: _updateEditedUTC')));

          };

        }

      }

​

      oneCompleted();

    }

​

    read(

      fullPath: string,

      callback: (error: Error, properties: { [property: string]: string; }) => void): void {

​

      var transaction = this._db.transaction('files');

      transaction.onerror = (errorEvent) => callback(wrapErrorEvent(errorEvent, 'read: transaction'), null);

      var filesStore = transaction.objectStore('files');

      var getRequest = filesStore.get(fullPath);

      getRequest.onerror = (errorEvent) => callback(wrapErrorEvent(errorEvent, 'read: get(' + fullPath +')'), null);